//package concurrent.no11;
//
//import org.apache.log4j.spi.LoggerFactory;
//
///**
// * 总消息队列管理
// */
//public class MsgQueueManager implements IMsgQueue {
//    private static final Logger LOGGER
//            = LoggerFactory.getLogger(MsgQueueManager.class);
//    /**
//     * 消息总队列
//     */
//    public final BlockingQueue<Message> messageQueue;
//
//    private MsgQueueManager() {
//        messageQueue = new LinkedTransferQueue<Message>();
//    }
//
//    public void put(Message msg) {
//        try {
//            messageQueue.put(msg);
//        } catch (InterruptedException e) {
//            Thread.currentThread().interrupt();
//        }
//    }
//
//    public Message take() {
//        try {
//            return messageQueue.take();
//        } catch (InterruptedException e) {
//            Thread.currentThread().interrupt();
//        }
//        return null;
//    }
//}